//package com.outdd.gateway.config;
//
//import org.apache.kafka.clients.admin.NewTopic;
//import org.springframework.context.annotation.Bean;
//import org.springframework.context.annotation.Configuration;
//
//@Configuration
//public class KafkaInitialConfiguration {
//
//    //创建TopicName为topic.quick.initial的Topic并设置分区数为8以及副本数为1
//    @Bean
//    public NewTopic initialTopic() {
//        NewTopic nc =new NewTopic("topic.quick.initial1",8, (short) 1 );
//        return nc;
//    }
//}